hudi系列

CSDN-Ada助手: AI 写作助手上线啦！限免 4 天，快来创作试试功能吧～https://editor.csdn.net/md/?not_checkout=1&utm_source=blog_comment_recall

阿浩_: 大佬，在使用同步pg时，会不会遇到锁表的问题，我在开发环境只验到 AccessShareLock；问了gpt，说了好几种锁，请问一下它的说法对不对？ [code=plain] 在使用 Flink CDC 2.3 同步 PostgreSQL 数据时，对于每个被同步的数据表，在进行快照时可能会产生如下几种类型的锁： ACCESS SHARE 锁 ACCESS SHARE 锁是 PostgreSQL 中最基本、最低级别的锁，因为它不会阻塞任何其他操作。它允许读取表中数据，并且与其他 ACCESS SHARE 锁兼容。Flink CDC 在进行快照时，会针对每个数据表获取 ACCESS SHARE 锁，以确保在快照期间不会有其他事务执行写入操作。 ROW SHARE 锁 ROW SHARE 锁是用于并发读取和修改数据的一种锁。当一个事务试图获取 ROW SHARE 锁时，它会被阻塞，直到没有任何其他事务持有 CONFIRMED、EXCLUSIVE 或 SHARE ROW EXCLUSIVE 锁。在 Flink CDC 进行快照期间，ROW SHARE 锁会防止其他事务修改数据表中的行。 SHARE UPDATE EXCLUSIVE 锁 SHARE UPDATE EXCLUSIVE 锁是允许同时进行并发读取和修改操作的锁。当一个事务试图获取 SHARE UPDATE EXCLUSIVE 锁时，它会被阻塞，直到没有任何其他事务持有 SHARE UPDATE EXCLUSIVE 锁或 EXCLUSIVE 锁。在 Flink CDC 进行快照期间，SHARE UPDATE EXCLUSIVE 锁会防止其他事务新增或删除数据。 SHARE ROW EXCLUSIVE 锁 SHARE ROW EXCLUSIVE 锁允许并发读取数据，但阻止其他事务修改或删除数据，除非它们持有 SHARE ROW EXCLUSIVE 或 SHARE UPDATE EXCLUSIVE 锁。在 Flink CDC 进行快照期间，SHARE ROW EXCLUSIVE 锁会防止其他事务修改数据表中的行。 ROW EXCLUSIVE 锁 ROW EXCLUSIVE 锁是指禁止其他事务对其中一行进行写入操作。在 Flink CDC 快照期间，ROW EXCLUSIVE 锁可能用于 [/code]

矛始: 最近在整理pg-cdc 1.x的流程，至于使用demo参考官方文档即可

阿浩_: 大佬，写一篇flink cdc 读取 postgresql，教学呗，学习学习一下

shsh1234567890: 非常好，学习了，nice啊